package com.cxb.springboot.listener.rabbitmq;


import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

import java.time.LocalDateTime;
import java.util.Date;

import static com.cxb.springboot.config.rabbitmq.DelayedQueueConfig.DELAYED_QUEUE_NAME;


/**
 * @Classname DelayQueueConsumer
 * @Date 2023/9/12 23:46
 * @Created by Administrator
 * @Description TODO
 */
@Slf4j
@Component
public class DelayQueueConsumer {

    @RabbitListener(queues = DELAYED_QUEUE_NAME)
    public void receiveDelayedQueue(Message message) {
        String msg = new String(message.getBody());
        log.info("当前时间：{},收到延时队列的消息：{}", LocalDateTime.now(), msg);
    }
}
